package com.flow.asyncflow.test.manager.asyncflowtest;


import com.flow.asyncflow.test.validator.asyncflowtest.Test_Plus_1_Validator;
import com.flow.asyncflow.test.operator.asyncflowtest.Test_Plus_1_Operator;
import com.flow.asyncflow.test.operator.asyncflowtest.Test_Plus_2_Operator;
import com.flow.asyncflow.test.operator.asyncflowtest.Test_Plus_3_Operator;
import com.flow.asyncflow.test.operator.asyncflowtest.Test_Plus_4_Operator;
import com.flow.asyncflow.test.operator.asyncflowtest.Test_Plus_5_Operator;
import com.flow.asyncflow.test.operator.asyncflowtest.Test_Plus_6_Operator;
import com.flow.asyncflow.test.operator.asyncflowtest.Test_Plus_7_Operator;
import com.flow.asyncflow.test.operator.asyncflowtest.Test_Plus_8_Operator;
import com.flow.asyncflow.test.operator.PubNode.Test_Plus_PubFlowNode_2_Operator;
import com.flow.asyncflow.test.operator.PubNode.Test_Plus_PubFlowNode_1_Operator;
import com.flow.asyncflow.core.annotation.FlowInfo;
import com.flow.asyncflow.core.core.AsyncFlowManager;
import com.flow.asyncflow.core.enums.ExecuteEnum;
import  com.flow.asyncflow.test.asyncflow.context.plusasyncflowtest.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * 测试异步流Plus
 *
 * @author 系统自动生成
 * @since 2022-06-25 16:27:20
 */
@Service
@FlowInfo(flowName = "测试异步流Plus",
        flowMaintainName = "07612",
        timeOutsLimit = 100)
public class PlusAsyncFlowTestManager extends AsyncFlowManager<com.flow.asyncflow.test.asyncflow.context.plusasyncflowtest.PlusAsyncFlowTestContext, com.flow.asyncflow.test.asyncflow.operatorenum.plusasyncflowtest.PlusAsyncFlowTestOperatorEnum> {

    @Autowired
    private Test_Plus_1_Validator m_Test_Plus_1_Validator;
    @Autowired
    private com.flow.asyncflow.test.getdata.asyncflowtest.Test_Plus_1_GetData m_Test_Plus_1_GetData;
    @Autowired
    private com.flow.asyncflow.test.getdata.asyncflowtest.Test_Plus_2_GetData m_Test_Plus_2_GetData;
    @Autowired
    private Test_Plus_1_Operator m_Test_Plus_1_Operator;
    @Autowired
    private Test_Plus_2_Operator m_Test_Plus_2_Operator;
    @Autowired
    private Test_Plus_3_Operator m_Test_Plus_3_Operator;
    @Autowired
    private Test_Plus_4_Operator m_Test_Plus_4_Operator;
    @Autowired
    private Test_Plus_5_Operator m_Test_Plus_5_Operator;
    @Autowired
    private Test_Plus_6_Operator m_Test_Plus_6_Operator;
    @Autowired
    private Test_Plus_7_Operator m_Test_Plus_7_Operator;
    @Autowired
    private Test_Plus_8_Operator m_Test_Plus_8_Operator;
    @Autowired
    private Test_Plus_PubFlowNode_2_Operator m_Test_Plus_PubFlowNode_2_Operator;
    @Autowired
    private Test_Plus_PubFlowNode_1_Operator m_Test_Plus_PubFlowNode_1_Operator;


    @Override
    protected void managerStartup() {
        addFlowNode(ExecuteEnum.Validator, m_Test_Plus_1_Validator, false);//测试异步流Plus验证1

        addFlowNode(ExecuteEnum.GetData, m_Test_Plus_1_GetData, true);//测试异步流Plus查询1

        addFlowNode(ExecuteEnum.GetData, m_Test_Plus_2_GetData, true);//测试异步流Plus查询2

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_1_Operator, true);//测试异步流Plus操作1

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_2_Operator, true);//测试异步流Plus操作2

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_3_Operator, true);//测试异步流Plus操作3

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_4_Operator, true);//测试异步流Plus操作4

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_5_Operator, true);//测试异步流Plus操作--构建公共节点请求参数

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_6_Operator, false);//测试异步流Plus操作6

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_7_Operator, false);//测试异步流Plus操作7

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_8_Operator, false);//测试异步流Plus操作8

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_PubFlowNode_2_Operator, true);//测试异步流公共节操作点1

        addFlowNode(ExecuteEnum.Operator, m_Test_Plus_PubFlowNode_1_Operator, true);//测试异步流公共节操作点

    }


}
